package com.example;

public class CanalCdcUserInsertUpdate extends CanalCdcBase {

    @Override
    protected String getJsonFilePath() {
        return "data_simulator/canal_cdc_insert_update.json";
    }

    public static void main(String[] args) {
        CanalCdcUserInsertUpdate canalCdc = new CanalCdcUserInsertUpdate();
        canalCdc.processCanalMessages();
    }
} 